package main

import (
	"fmt"
	"net"
	"os"
	"strconv"
	"time"
)

func main() {
	// 获取客户端参数
	para := os.Args // go run client.go --nodeID 8000 --data "hello world"

	// 主动发送连接请求
	conn, err := net.Dial("tcp", "localhost:"+para[2])

	if err != nil {
		fmt.Println("Dial err", err)
	}

	defer conn.Close() // 客户端终止时，关闭于服务器通讯的socket

	// 发送数据
	startTime := time.Now().UnixNano()

	data := para[4] + "_" + strconv.Itoa(int(startTime))

	// 将命令行中的数据，发送给客户端
	_, err = conn.Write([]byte(data))
	if err != nil {
		fmt.Println("conn.Write err:", err)
		return
	}
}
